package com.cloud.stream.receiver;

import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.SpringApplicationConfiguration;
import org.springframework.integration.support.MessageBuilder;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.test.context.web.WebAppConfiguration;

import com.cloud.stream.Application;

@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(classes = Application.class)
@WebAppConfiguration
public class Test {

	
	
	@Autowired
	private SinkSender sinkSender;
	
	@org.junit.Test
	public void contextLoads(){
		sinkSender.outPut().send(MessageBuilder.withPayload("{\"name\":\"didi\",\"age\":30}").build());
	}
	
}
